package com.jeffse.light.stream.app.function;

import com.jeffse.light.stream.core.data.context.ProcessContext;
import com.jeffse.light.stream.core.function.base.ProcessFunction;
import lombok.extern.slf4j.Slf4j;

@Slf4j
public class ProcessAFunction extends ProcessFunction<String, String> {

    @Override
    public void processElement(ProcessContext context, String value) throws Exception {
        context.collect(value + "A");
    }
}
